package com.x.rocketmq.constant;

/**
 * @author xjk
 * @date 2025-07-03
 */
public class RocketMQConstants {
  public static final String SUCCESSCODE = "0000";

  public static final String SUCCESSMSG = "成功";

  public static final String ROCKETMQ_SEND_ERRORCODE = "1000";

  public static final String ROCKETMQ_SEND_ERRORMSG = "【rocketMQ消息发送失败】";

  public static final String ROCKETMQ_NO_RESULTCODE = "1001";

  public static final String ROCKETMQ_NO_RESULTMSG = "rocketMQ没有查找到返回结果集";

  public static final String ROCKETMQ_DB_ERRORCODE = "1002";

  public static final String ROCKETMQ_DB_ERRORMSG = "消息保存至数据库异常";

  public static final String ROCKETMQ_MONGODB_ERRORCODE = "1003";

  public static final String ROCKETMQ_MONGODB_ERRORMSG = "消息保存至mongodb异常";

  /**
   * 订阅该队列下的所有标签
   */
  public final static String SUB_ALL = "*";

  /**
   * 是否开启消息压缩
   */
  public static final boolean IS_COMPRESSION_ZIP = true;

}
